package net.zoneland.knowledge.dao;

import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;

import java.util.List;

@Mapper
public interface CheckSyncSftpMapper {

    /**
     * 时间范围内，都没有导入成功的数据类型。
     * @param time
     * @return
     */
    @Select({
            "select SYNC_TYPE from AITK_SYNC_SFTP where SYNC_DATE >= #{time} ",
            " group by SYNC_TYPE having sum(IMPORT_DATA) = 0"
    })
    List<String> getSftpRecordByTimeForAllSync(final String time);

    /**
     * 获取这个时间点没有成功导入的增量类型，目前只有三会一课和党费。
     * @param time
     * @return
     */
    @Select({
            "select SYNC_TYPE from AITK_SYNC_SFTP where SYNC_DATE = #{time} ",
            " and SYNC_TYPE in ('SHYK', 'DF') and IMPORT_DATA = 0"
    })
    List<String> getIncrementTypeForNotImport(final String time);
}
